<?php

namespace wxpay;

require_once "WxPayData.php";
require_once "Wxpayapi.php";

use app\common\model\Coreorder;

/**
 * 
 * 回调基础类
 * @author widyhu
 *
 */
class WxPayNotify extends WxPayNotifyReply
{
    /**
     * 
     * 回调入口
     * @param bool $needSign  是否需要签名输出
     */
    final public function Handle($needSign = true)
    {
        $msg = "OK";
        //当返回false的时候，表示notify中调用NotifyCallBack回调失败获取签名校验失败，此时直接回复失败
        $result = Wxpayapi::notify(array($this, 'NotifyCallBack'), $msg);
        if ($result == false) {
            $this->SetReturn_code("FAIL");
            $this->SetReturn_msg($msg);
            $this->ReplyNotify(false);
            return;
        } else {
            //该分支在成功回调到NotifyCallBack方法，处理完成之后流程
            $this->SetReturn_code("SUCCESS");
            $this->SetReturn_msg("OK");
        }
        $this->ReplyNotify($needSign);
    }

    /**
     * 
     * 回调方法入口，子类可重写该方法
     * 注意：
     * 1、微信回调超时时间为2s，建议用户使用异步处理流程，确认成功之后立刻回复微信服务器
     * 2、微信服务器在调用失败或者接到回包为非确认包的时候，会发起重试，需确保你的回调是可以重入
     * @param array $data 回调解释出的参数
     * @param string $msg 如果回调处理失败，可以将错误信息输出到该方法
     * @return true回调出来完成不需要继续回调，false回调处理未完成需要继续回调
     */
    public function NotifyProcess($data, &$msg)
    {
        //TODO 用户基础该类之后需要重写该方法，成功的时候返回true，失败返回false
        return true;
    }

    /**
     * 
     * notify回调方法，该方法中需要赋值需要输出的参数,不可重写
     * @param array $data
     * @return true回调出来完成不需要继续回调，false回调处理未完成需要继续回调
     */
    final public function NotifyCallBack($data)
    {
        $msg = "OK";
        $result = $this->NotifyProcess($data, $msg);

        if ($result == true) {
            $this->SetReturn_code("SUCCESS");
            $this->SetReturn_msg("OK");
        } else {
            $this->SetReturn_code("FAIL");
            $this->SetReturn_msg($msg);
        }
        return $result;
    }

    /**
     * 
     * 回复通知
     * @param bool $needSign 是否需要签名输出
     */
    final private function ReplyNotify($needSign = true)
    {
        //如果需要签名
        if (
            $needSign == true &&
            $this->GetReturn_code() == "SUCCESS"
        ) {
            $this->SetSign();
        }
        WxPayApi::replyNotify($this->ToXml());
    }

    /**
     *
     * 回调入口
     * @param bool $needSign  是否需要签名输出
     */
    final public function ImportHandle($xml)
    {
        $msg = "OK";
        $callarray = $this->FromXml($xml);
        if (is_array($callarray) && count($callarray) && isset($callarray['attach'])) {
            if (!empty($callarray['attach'])) {
                $attach = json_decode($callarray['attach'], true);
                $user_id = $attach['user_id'];
                $payfee = $attach['payfee'];
            }

            $out_trade_no = $callarray['out_trade_no'];

            // $payment = payment::find('payment_sn=?', $out_trade_no)->getOne();
            // if (!$payment->id()) {
            //     echo '支付单未找到';
            //     die;
            // }
            $coreorder = Coreorder::where('order_no', $out_trade_no)->find();
            //dump($coreorder);die;
            if (!$coreorder) {
                echo '订单未找到';
                die;
            }

            $wxmchid = config('site.wxmchid');
            $wxkey = config('site.wxkey');
            $wxappid = config('site.appid');
            $wxappsecret = config('site.appsecret');

            WxPayConfig::setconfig($wxmchid, $wxkey, $wxappid, $wxappsecret);


            $result = WxPayApi::notify(array($this, 'NotifyCallBack'), $msg, $xml);
            //验证成功,写逻辑
            if ($result == true) {


                // 商户订单号
                $out_trade_no = $callarray['out_trade_no'];
                // 交易号
                $trade_no = $callarray['transaction_id'];
                // 交易状态
                $trade_status = $callarray['return_code'];

                $pay_fee = floatval($callarray['total_fee'] / 100);
                //dump($pay_fee);die;
                $notify_time = time();
                //多次访问

                if ($coreorder->status >= 1) {
                    echo '订单已经支付，请不要重复支付';
                    die;
                }
                if ($coreorder->fee == $pay_fee) {
                    //支付完成
                    $coreorder->trade_no = $trade_no;
                    $coreorder->notifytime = $notify_time;
                    $coreorder->save();

                    $order = coreorder::notifyOK($coreorder->id);
                } else {
                    echo '非法请求';
                    die;
                }

                if ($coreorder) {

                    $this->SetReturn_code("SUCCESS");
                    $this->SetReturn_msg("OK");
                    $this->ReplyNotify();
                } else {
                    $this->SetReturn_code("FAIL");
                    $this->SetReturn_msg($msg);
                    $this->ReplyNotify(false);
                    $this->ReplyNotify();
                }
            } else {
                echo ('OK');
            }
        }
    }
}
